#!/usr/bin/python
# -*- coding: utf-8 -*-
import os
import rospy
from threading import Thread, Event
from ros_mqtt.mqqt_sender import CommandSender


def main():
    try:
        NODE_NAME = os.path.basename(__file__)
        rospy.init_node(NODE_NAME, disable_signals=True)
        rospy.loginfo('Start node : %s'%NODE_NAME)
        sender = CommandSender(NODE_NAME)
        sender.connect().start()
    except rospy.ROSInterruptException:
        pass


if __name__ == '__main__':
    main()
